03ade425dd5a65d3a713d5e7d85aa7605956fbd2,giraph-core/src/main/java/org/apache/giraph/worker/BspServiceWorker.java,BspServiceWorker,storeCheckpointVertices,#,1502
Before Change
GiraphConstants.NUM_CHECKPOINT_IO_THREADS.get(getConfiguration()),
numPartitions);
final Queue<Integer> partitionIdQueue =
(numPartitions == 0) ? new LinkedList<Integer>() :
new ArrayBlockingQueue<Integer>(numPartitions);
Iterables.addAll(partitionIdQueue, getPartitionStore().getPartitionIds());
final CompressionCodec codec =
new CompressionCodecFactory(getConfiguration())
After Change
GiraphConstants.NUM_CHECKPOINT_IO_THREADS.get(getConfiguration()),
numPartitions);
getPartitionStore().startIteration();
final CompressionCodec codec =
new CompressionCodecFactory(getConfiguration())